package com.youxin.dataStream.dataTypeAndSerilser;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import java.util.stream.Stream;

/**
 * flink的序列化
 * 如果没有开启这几个序列化的话使用的是哪一个   ， 这块还是有点疑问
 */
public class StreamSerilzer {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.getConfig().enableForceKryo();//使用kryo序列化
        env.getConfig().enableForceAvro();//使用avro序列化

        //自定义的序列化
        //env.getConfig().addDefaultKryoSerializer();


    }
}
